package net.xo68.destiny.starter.manager.sched;

/**
 * 触发观察提供者
 * @author wuxie
 * @version 2020-12-27
 */
public interface JobTriggerObserverProvider {

    /**
     * 观察任务并进行处理
     * @param runnable
     * @param bufferTimeSecond 缓冲时间秒数
     * @param triggerObserverMaxSize 每次最大观察数量
     */
    void oberveJob(Runnable runnable, long bufferTimeSecond,int triggerObserverMaxSize);
}
